视频|一步步教你操作websocket通知案例

1. 我们不能保证用户B和用户A都处于连接状态&＃xff0c;但是通常情况下&＃xff0c;用户B至少是连接状态&＃xff0c;用户A不一定跟server保持连接&＃xff1b;

2. 任一用户都不止对应一个客户端。换言之&＃xff0c;用户A和用户B都可能打开了多个tab页&＃xff0c;对于一个tab页&＃xff0c;就会有一个独立的fd标识&＃xff0c;我们这里认为任一用户只有最新的fd有效&＃xff0c;或者你可以认为用户所有的tab页的连接都有效&＃xff1b;

3. 因为没有用户系统&＃xff0c;我们以get传递的参数uid为标识&＃xff0c;uid&＃61;100视为用户A&＃xff0c;uid&＃61;101视为用户B&＃xff1b;

4. 我们模拟的tab页包将会包含一个输入内容的文本框、一个输入目标uid的input和一个发送的按钮以满足需求。

1. 用户A&＃xff08;$_GET[&＃39;uid&＃39;] &＃61; 100&＃xff09;在某个tab页的输入框输入"回复xxx的内容"字样后&＃xff0c;点击发送

2. 用户B&＃xff08;$_GET[&＃39;uid&＃39;] &＃61; 101&＃xff09;如果处于连接状态&＃xff0c;则alert提醒用户B&＃xff0c;他的评论被回复了

后端启动&＃xff1a;php server.php

class CommentServer
{private $_serv;public $key &＃61; &＃39;^manks.top&swoole$&＃39;;// 用户id和fd对应的映射,key &＃61;> value,key是用户的uid,value是用户的fdpublic $user2fd &＃61; [];public function __construct()
{$this->_serv &＃61; new swoole_websocket_server("127.0.0.1", 9501);$this->_serv->set([&＃39;worker_num&＃39; &＃61;> 1,&＃39;heartbeat_check_interval&＃39; &＃61;> 60,&＃39;heartbeat_idle_time&＃39; &＃61;> 125,]);$this->_serv->on(&＃39;open&＃39;, [$this, &＃39;onOpen&＃39;]);$this->_serv->on(&＃39;message&＃39;, [$this, &＃39;onMessage&＃39;]);$this->_serv->on(&＃39;close&＃39;, [$this, &＃39;onClose&＃39;]);}/*** &＃64;param $serv* &＃64;param $request* &＃64;return mixed*/public function onOpen($serv, $request)
{// 连接授权$accessResult &＃61; $this->checkAccess($serv, $request);if (!$accessResult) {return false;}// 始终把用户最新的fd跟uid映射在一起if (array_key_exists($request->get[&＃39;uid&＃39;], $this->user2fd)) {$existFd &＃61; $this->user2fd[$request->get[&＃39;uid&＃39;]];$this->close($existFd, &＃39;uid exists.&＃39;);$this->user2fd[$request->get[&＃39;uid&＃39;]] &＃61; $request->fd;return false;} else {$this->user2fd[$request->get[&＃39;uid&＃39;]] &＃61; $request->fd;}}/*** &＃64;param $serv* &＃64;param $frame* &＃64;return mixed*/public function onMessage($serv, $frame)
{// 校验数据的有效性&＃xff0c;我们认为数据被&＃96;json_decode&＃96;处理之后是数组并且数组的&＃96;event&＃96;项非空才是有效数据// 非有效数据&＃xff0c;关闭该连接$data &＃61; $frame->data;$data &＃61; json_decode($data, true);if (!$data || !is_array($data) || empty($data[&＃39;event&＃39;])) {$this->close($frame->fd, &＃39;data format invalidate.&＃39;);return false;}// 根据数据的&＃96;event&＃96;项&＃xff0c;判断要做什么,&＃96;event&＃96;映射到当前类具体的某一个方法&＃xff0c;方法不存在则关闭连接$method &＃61; $data[&＃39;event&＃39;];if (!method_exists($this, $method)) {$this->close($frame->fd, &＃39;event is not exists.&＃39;);return false;}$this->$method($frame->fd, $data);}public function onClose($serv, $fd)
{echo "client {$fd} closed.\n";}/*** 校验客户端连接的合法性,无效的连接不允许连接* &＃64;param $serv* &＃64;param $request* &＃64;return mixed*/public function checkAccess($serv, $request)
{// get不存在或者uid和token有一项不存在&＃xff0c;关闭当前连接if (!isset($request->get) || !isset($request->get[&＃39;uid&＃39;]) || !isset($request->get[&＃39;token&＃39;])) {$this->close($request->fd, &＃39;access faild.&＃39;);return false;}$uid &＃61; $request->get[&＃39;uid&＃39;];$token &＃61; $request->get[&＃39;token&＃39;];// 校验token是否正确,无效关闭连接if (md5(md5($uid) . $this->key) !&＃61; $token) {$this->close($request->fd, &＃39;token invalidate.&＃39;);return false;}return true;}/*** &＃64;param $fd* &＃64;param $message* 关闭$fd的连接&＃xff0c;并删除该用户的映射*/public function close($fd, $message &＃61; &＃39;&＃39;)
{// 关闭连接$this->_serv->close($fd);// 删除映射关系if ($uid &＃61; array_search($fd, $this->user2fd)) {unset($this->user2fd[$uid]);}}public function alertTip($fd, $data)
{// 推送目标用户的uid非真或者该uid尚无保存的映射fd&＃xff0c;关闭连接if (empty($data[&＃39;toUid&＃39;]) || !array_key_exists($data[&＃39;toUid&＃39;], $this->user2fd)) {$this->close($fd);return false;}$this->push($this->user2fd[$data[&＃39;toUid&＃39;]], [&＃39;event&＃39; &＃61;> $data[&＃39;event&＃39;], &＃39;msg&＃39; &＃61;> &＃39;收到一条新的回复.&＃39;]);}/*** &＃64;param $fd* &＃64;param $message*/public function push($fd, $message)
{if (!is_array($message)) {$message &＃61; [$message];}$message &＃61; json_encode($message);// push失败&＃xff0c;closeif ($this->_serv->push($fd, $message) &＃61;&＃61; false) {$this->close($fd);}}public function start()
{$this->_serv->start();}
}$server &＃61; new CommentServer;
$server->start();
前端页面 client.php

回复关键字获取资源链接&＃xff1a;

wokerman实战之PHP在线客服&＃xff1a;wokerman